package com.sdemo.utils.mq.activemq;

public interface MsgHandler<T> {
	/**
	 * 消息处理
	 * @param msg
	 */
	public void onMsg(T msg);
	/**
	 * 返序列化
	 * @param buf
	 * @return
	 */
	public T deserializer(byte[] buf);
	
}
